package com.mq.util;

import com.mq.dpca.file.MQFileReceiver;
import com.mq.dpca.file.MQFileSender;
import com.mq.dpca.msg.MsgSend;

public class MQMSGSendUtil {
	/**
	 * 发送消息 
	 * @param key  服务名称
	 * @param msg  需要发送的数据
	 */
	public void sendMsg(String key,String msg){
		MsgSend send = new MsgSend();
		send.send(key, msg);
	}
	/**
	 * 发送文件，可以超过500兆
	 * @param key  服务名称
	 * @param sourceApp  发送方系统
	 * @param filedir    文件的路径，文件不能以多个.分开，只允许“文件名.后缀”方式
	 */
	public void sendFile(String key,String sourceApp,String filedir){
		MQFileSender fileSender = new MQFileSender();
		fileSender.sendFile(key, sourceApp, filedir);
	}
	
	
	/**
	 * 接收文件服务 ,接收信息需要在jar包里面填写配置文件，相关信息从ESB获取
	 * @param fileDir   文件存放地址  需要以\结尾，例如C:\\ref\
	 */
	public void reciveFile(String fileDir){
		MQFileReceiver fileReceiver = new MQFileReceiver();
		fileReceiver.fileReciveDir(fileDir);
	}

	public static void main(String[] args) {
		MQMSGSendUtil mqmsgSendUtil = new MQMSGSendUtil();
		mqmsgSendUtil.sendFile("service11", "ehr", "D:\\jdk1_6_0_43.rar");
//		mqmsgSendUtil.reciveFile("D:\\re\\");
	}
}
